package com.huatai.bi.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.huatai.bi.dto.DataSynDto;
import com.huatai.bi.dto.DataSynPrarmDto;
import com.huatai.bi.entity.DataSynrecordEntity;

import java.util.List;

/**
* @author hecai
* @description 针对表【tb_data_synrecord(数据同步创建记录表)】的数据库操作Service
* @createDate 2024-07-04 15:32:32
*/
public interface DataSynrecordService extends IService<DataSynrecordEntity> {

    /**
     * 数据同步任务生成
     * @param prarmDto
     * @return
     */
    //void generateDataSynTask(DataSynPrarmDto prarmDto);
    List<String> generateDataSynTask(DataSynPrarmDto prarmDto);

    void addTableInfo(DataSynPrarmDto prarmDto);

    /**
     * 创建数据同步任务
     * @param dtId
     * @param dataType
     * @param dataSynDto
     * @return
     */
    String createDataSynTask(Long dtId,Integer dataType,DataSynDto dataSynDto);

    /**
     * 单表数据同步
     * @param dirId
     * @param tableId
     */
    void execOneTableSyn(Long dirId,Long tableId);

    /**
     * 修改调度
     * @param id
     * @param cron
     * @return
     */
    boolean editDataSynrecord(Long id, String cron);

    void removeByDtId(Long dtId);
}
